const mysql = require('mysql');

let config = { // 配置
  // connectionLimit: 10, // 默认10，最大连接数量
  host: '127.0.0.1', // 数据库地址 
  port: 3306, // 数据库端口号 
  user: 'root', // 数据库连接账号
  password: '123456', // 密码
  database: 'w290', // 数据库名
}

function query(sql, options) {
  return new Promise((resolve, reject) => {
    var pool = mysql.createPool(config);
    pool.getConnection((err, connection) => {
      if (err) {
        console.log('连接失败：', err);
        return reject(err)
      }
      connection.query(sql, options, (error, doc) => {
        connection.release(); // 释放连接池
        if (error) {
          console.log('sql 操作失败', error);
          return reject(error);
        }

        console.log('sql 操作成功', doc);
        resolve(doc);
      })
    })
  })
}

module.exports = query;